# -*- coding=utf-8 -*-
# Created Time: 2016年08月29日 星期一 16时35分01秒
# File Name: sync_to_qiniu.py

"""
通过 MD5 值 同步文件到 七牛
"""

from tornado.options     import options
from configure           import mq_conf
from stormed             import Message

import json


def sync(file_md5):
    """ 通过 MD5 值 同步文件到 七牛 """

    ch = options['ch']

    request = Message(
        json.dumps({"md5": file_md5}),
        delivery_mode = 2,
        headers = {
            "md5"    : file_md5,
            "private": "0"
        }
    )

    ch.publish(
        request,
        exchange    = mq_conf.Sync_CDN_Exchange,
        routing_key = mq_conf.Sync_CDN_Queue
    )


